package com.miyu.rabbitmq.service;

import com.alibaba.fastjson2.JSONObject;
import com.miyu.rabbitmq.pojo.SysMqConfig;

import java.util.List;

public interface RabbitService {
    /**
     * 新增消息队列
     * @param mqConfig 配置信息
     * @return
     */
    JSONObject add(SysMqConfig mqConfig);

    /**
     * 修改消息队列
     * @param mqConfig 配置信息
     * @return
     */
    JSONObject update(SysMqConfig mqConfig);

    /**
     * 删除消息队列
     * @param mqIds
     * @return
     */
    JSONObject delete(String[] mqIds);

    /**
     * @param params
     * @return
     */
    JSONObject sendMessage(JSONObject params);

    /**
     * @param params
     */
    void recieveMessage(JSONObject params);

    /**
     * 查询系统mqconfig
     *
     * @param params
     * @return
     */
    List<SysMqConfig> querySysMqConfig(JSONObject params);

}
